package org.apache.flink.runtime.resourceconsumer.factories;

import java.util.UUID;

import org.apache.flink.api.common.ConsumerID;
import org.apache.flink.runtime.resourceconsumer.ResourceConsumerServiceProcess;

/**
 * @类名: ResourceConsumerServiceProcessFactory
 * @说明: 资源消费者服务处理工厂
 *
 * @author   leehom
 * @Date	 2023年10月31日 下午5:39:48
 * 修改记录：
 *
 * @see 	 
 */
public interface ResourceConsumerServiceProcessFactory {

    /**
     * Create a new {@link ResourceConsumerServiceProcess} for the given leaderSessionId.
     *
     * @param leaderSessionId leaderSessionId for which to create a {@link ResourceConsumerServiceProcess}
     * @return the newly created {@link JobMasterServiceProcess}
     */
	ResourceConsumerServiceProcess create(UUID leaderSessionId);

    /**
     * Gets the {@link JobID|ConsumerID} of the consumer for which this factory creates {@link
     * ResourceConsumerServiceProcess}.
     */
    ConsumerID getConsumerId();

}
